package com.ot.flink.cdc.function.sink;

/**
 * todo
 *
 * @author: admin
 * @date: 2024/5/9
 * @since JDK1.8 version: 1.0.0
 */
public class SinkFactory {

    public static KafkaSink getInstance() {
        return new KafkaSink();
    }
    public static CustomSink getInstance2() {
        return new CustomSink();
    }
}
